package com.j2boot.semaphore;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * 整型信号量
 * @author yichengxian
 */
public class intSemaphore {

    /**
     * P操作
     *
     * @param s
     */
    public void wait(AtomicInteger s) {
        while (s.get() <= 0) ;
        s.decrementAndGet();
    }

    /**
     * V操作
     * @param s
     */
    public void signal(AtomicInteger s) {
        s.incrementAndGet();

    }

}

